import os
from celery import Celery

os.environ.setdefault("DJANGO_SETTINGS_MODULE", "fuguangweb.settings.dev")  # 设置项目的配置文件
app = Celery('proj')
app.config_from_object('django.conf:settings', namespace='CELERY')
app.autodiscover_tasks()

from datetime import timedelta

app.conf.beat_schedule = {
    'add-every-30-seconds':{
        'task':'user.task.add',  # 定时任务要执行的函数
        'scheule':timedelta(seconds=30), # 定时任务要的执行间隔
        'args':(10,20) # 传递给任务的参数
    },
    'add-every-60-seconds':{
        'task':'user.task.send', # 定时任务要执行的函数
        'scheule':timedelta(seconds=120), # 定时任务要的执行间隔
        'args':('18119141389','2345') # 传递给任务的参数
    }
}